package com.atguigu.sparkcore.rdd.file.`object`

import com.atguigu.sparkcore.util.MySparkContextUtil

/**
 * description ：将rdd保存为object文件
 * author ：剧情再美终是戏
 * mail : 13286520398@163.com
 * date ：Created in 2020/1/8 21:12
 * modified By ：
 * version: : 1.0
 */
object WObjectFile {

  def main(args: Array[String]): Unit = {

    // 创建sparkContext
    val sc = MySparkContextUtil.get(args)

    // 创建rdd
    val rdd = sc.parallelize(Array(("o1", 1), ("o2", 2), ("o3", 3), ("o4", 4), ("o5", 5)), 2)

    // 将rdd保存为Object文件
    rdd.saveAsObjectFile("c:/outputobj")

    // 关闭sparkContext资源
    MySparkContextUtil.close(sc)
  }

}
